package cn.com.tt.flink.sql.engine;

import cn.com.tt.flink.runner.FlinkRunner;
import cn.com.tt.flink.sql.engine.processor.JobProcessorBuilder;

public class Application {

    public static void main(String[] args) throws Exception {
        //运行flink程序
        new FlinkRunner(new JobProcessorBuilder(args)).run();
    }
}
